package com.gubatian.dfs.namenode.server;

/**
 * NameNode的RPC服务的接口
 *
 * @author: gubatian
 * @create: 2021-09-22 18:50
 */
public class NameNodeRpcServer {
    /**
     * 负责管理元数据的核心组件
     */
    private FSNameSystem fsNameSystem;
    public NameNodeRpcServer(FSNameSystem fsNameSystem) {
        this.fsNameSystem = fsNameSystem;
    }

    /**
     * 创建目录
     * @param path 路径
     * @return 是否创建成功
     * @throws Exception
     */
    public boolean mkdir(String path) throws Exception {
        return fsNameSystem.mkdir(path);
    }

    public void start() {
        System.out.println("开始监听指定的RPC Server端口号，来接受请求");
    }
}